import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

public class ParquetReadApp {
    public static void main(String[] args) {
        SparkSession spark = SparkSession.builder()
                .appName("ParquetApp")
                //.master("local[*]")  // 本地运行
                .getOrCreate();
        String outputPath = "oss://risk-ml-featurestore/w-93b109b38a92c892/spark-warehouse/wx_encrypted_people_1";
        Dataset<Row> decryptedData = spark.read().parquet(outputPath);
        System.out.println("读取解密文件：");
        decryptedData.show();

        spark.stop();
    }
}
